package com.cwm;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;


@SpringBootApplication
public class Start {
    public static void main(String[] args) {
        SpringApplication.run(Start.class, args);
    }
//    // Consumer消费函数，在stream当中用来当中接受消息者
//    @Bean
//    public Consumer<String> sink() {
//        return message -> {
//            System.out.println("----------------sink:" + message + "---------------");
//        };
//    }
//
//
//    // 供应商函数，就是发送消息者，供应消息的
//    @Bean
//    public Supplier<String> source() {
//        return () -> {
//            String message = "from source";
//            System.out.println("------------------from source--------------");
//            return message;
//        };
//    }



}
